package com.atguigu.flink;

import com.streamxhub.streamx.flink.core.TableContext;
import com.streamxhub.streamx.flink.core.TableEnvConfig;

/**
 * @Author lzc
 * @Date 2022/3/30 16:35
 */
public class StreamXSql {
    public static void main(String[] args) {
        TableEnvConfig conf = new TableEnvConfig(args, null);
        TableContext ctx = new TableContext(conf);
        
        ctx.sql("first");
    }
}
